package com.flowable.project.test;



import com.flowable.project.rocketmq.PayProducer;
import com.flowable.project.util.SpringUtil;
import org.flowable.common.engine.api.delegate.Expression;
import org.flowable.engine.RuntimeService;
import org.flowable.engine.delegate.DelegateExecution;
import org.flowable.engine.delegate.JavaDelegate;


public class xxx implements JavaDelegate {
    @Override
    public void execute(DelegateExecution execution) {
        PayProducer producer = new PayProducer();
        String executionId = execution.getId();
//        RuntimeService runtimeService = SpringUtil.getBean(RuntimeService.class);
//        runtimeService.messageEventReceived("isok",executionId);
        System.out.println("================"+executionId+"=================");
        producer.sendMessage(executionId,"",executionId);
        System.out.println(executionId+"的消息发送的消息对列成功！！！xxxxxxxxxx");
    }
}
